package com.bwie.config;

import org.apache.kafka.clients.admin.NewTopic;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @Author: lrz
 * @Date: 2024/10/22 18:10
 * @Description:
 **/
@Configuration
public class KafkaConfig {

    //创建测试发送消息
    @Bean
    public NewTopic topicTest(){
        return new NewTopic("topic-test",1,(short) 1);
    }
}
